package cn.tramy.pinxian.wind.eventstore.storage

import cn.tramy.pinxian.wind.eventstore.query.entry.DomainEventEntry
import reactor.core.publisher.Flux

interface EventStorage {
    fun persistent(eventEntry: DomainEventEntry)
    fun readEventEntry(aggregateId: String, aggregateType: String): Flux<DomainEventEntry>
}